package com.csx.governance.traffic.mq.rocketmq;

import org.apache.rocketmq.spring.core.RocketMQListener;

/**
 * 单向消费消息
 * @author cuisongxu
 * @date 2023/2/28 17:13
 */
public class TrafficRocketMQListener implements RocketMQListener<String> {

    @Override
    public void onMessage(String message) {
        System.out.println("TrafficRocketMQListener#onMesage()");
    }
}
